// ============================================================ //
// ============================================================ //
//
// @Group       : QiXin Supply Chain Team
// @Author      : ZhiQiang Cheng
// @Date        : 2024-07-15
// @Description : 团购通知DAO
//
// ============================================================ //
// ============================================================ //

package dao

import (
	"wooha-cache-hub/model"

	"github.com/StarfishProgram/starfish-go-sdk/sdkdb"
	"github.com/StarfishProgram/starfish-go-sdk/sdktypes"
)

type groupBuyingRoomNotice struct{}

var GroupBuyingRoomNotice = new(groupBuyingRoomNotice)

// ============================================================ //
// 查询房间通知
// ============================================================ //

func (gbrn *groupBuyingRoomNotice) GetByRoomId(id sdktypes.ID, limit int) ([]*model.GroupBuyingRoomNoticeDetail, error) {
	var list []*model.GroupBuyingRoomNoticeDetail
	sql := sdkdb.Ins().Table("group_buying_room_notice rn")
	sql.Joins("left join product p on rn.product_id = p.id")
	sql.Where("rn.room_id = ?", id)
	sql.Order("rn.id desc")
	sql.Select("rn.*, p.name as product_name")
	err := sql.Limit(limit).Find(&list).Error
	if err != nil {
		return nil, err
	}
	return list, nil
}
